﻿using KafkaUtil;
using KafkaUtil.Interface;
using NewLife.Collections;

namespace PtlSvr.Model
{
    public class ProducerPool : ObjectPool<IClientProducer>
    {
        public KafkaProducerOptions producerOptions { get; set; }

        protected override IClientProducer OnCreate() => new Kafka() { producerOptions = producerOptions }.GetProducer();
    }
}
